package com.yang.common.amqp.rabbit.constant;

/**
 * Fanout广播事件一般基于交换机来做
 * @author: Billyang
 * @date: 2024/9/17 23:18
 */
public interface FanoutConstants {
    String PREFIX = "fanout.";

    // 部署事件
    interface DEPLOY {
        // 交换机
        String EXCHANGE = PREFIX + "deploy";
    }

    // canal事件
    interface CANAL {
        // 交换机
        String EXCHANGE = FanoutConstants.PREFIX + "canal";

        String PREFIX = FanoutConstants.PREFIX + "canal.";
        // 队列
        String USER_QUEUE = PREFIX + "user";
        String ORDER_QUEUE = PREFIX + "order";
    }
}
